from kafka import KafkaProducer
import json
import time

# 创建生产者实例
producer = KafkaProducer(
    bootstrap_servers=['node3:9092'],  # 替换为你的Kafka服务器地址
    value_serializer=lambda v: json.dumps(v).encode('utf-8')  # 序列化消息值
)

topic_name = 'test'  # 替换为你的主题名称

try:
    for i in range(100):  # 发送5条消息作为示例
        message = {'number': i}
        print(f"Sending message: {message}")
        producer.send(topic_name, value=message)
        time.sleep(1)  # 模拟延迟，以便观察效果
finally:
    producer.flush()  # 确保所有消息都被发送出去
    producer.close()